//package com.ruoyi.system.websocket;
//
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Component;
//
//import java.io.IOException;
//import java.util.HashMap;
//import java.util.Set;
//
//@Component
//public class SendMessageClient {
//    @Scheduled(cron = "0/5 * * * * ？")
//    public void  send() throws IOException {
//        HashMap<String, WebSocketServer> webSocketServeHashMap = WebSocketServer.getWebSocketServeHashMap();
//        Set<String> carIDs = webSocketServeHashMap.keySet();
//        if (carIDs.size()<=0){
//            System.out.println("当前没有连接,不发消息");
//            return;
//        }
//        //自定义发送消息
//        for (String carID : carIDs) {
//            //redis hbase mysql 数据真实的
//            String message="服务器端发送的消息"+"[12354.15424]";
//            WebSocketServer.sendInfo(message,carID);
//        }
//    }
//
//}
